//package com.gyt.manager.conf;
//
//import com.dangdang.ddframe.job.config.JobCoreConfiguration;
//import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
//import com.dangdang.ddframe.job.lite.api.JobScheduler;
//import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
//import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;
//import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
//import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
//import com.gyt.manager.job.MySimpleJob;
//import org.springframework.boot.CommandLineRunner;
//import org.springframework.context.annotation.Bean;
//import org.springframework.stereotype.Component;
//
///**
// * @author gyt created on 2021/5/16 17:22
// **/
//@Component
//public class ElasticJobConf {
//
//    private static CoordinatorRegistryCenter createRegistryCenter() {
//        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(
//                new ZookeeperConfiguration("192.168.0.101:2181", "ad-manager"));
//        regCenter.init();
//        return regCenter;
//    }
//
//    private static LiteJobConfiguration createJobConfiguration() {
//        // 定义作业核心配置
//        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
//                "demoSimpleJob", "0/15 * * * * ?", 10).build();
//
//        // 定义SIMPLE类型配置
//        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(
//                simpleCoreConfig, MySimpleJob.class.getCanonicalName());
//
//        // 定义Lite作业根配置
//        LiteJobConfiguration simpleJobRootConfig =
//                LiteJobConfiguration.newBuilder(simpleJobConfig).build();
//        return simpleJobRootConfig;
//    }
//
//    @Bean
//    public CommandLineRunner commandLineRunner() {
//        return (String... args) -> {
//            new JobScheduler(createRegistryCenter(), createJobConfiguration()).init();
//        };
//    }
//}
